package com.dsk.connector.sink.common.consumer;

import com.dsk.connector.commons.trans.TransMsg;
import org.apache.kafka.connect.source.SourceRecord;

public interface SinkConsumer {
    void consume(TransMsg transMsg) throws Exception;
}
